ab3f93d584560278d397767057d367191b424ed7,src/main/java/reactor/ipc/netty/channel/ChannelOperationsHandler.java,ChannelOperationsHandler,userEventTriggered,#ChannelHandlerContext#Object#,204

Before Change


			log.trace("User event {}", evt);
		}
		if (evt == NettyPipeline.handlerTerminatedEvent()) {
			parentContext().terminateChannel(ctx.channel());
			return;
		}
		if (evt instanceof NettyPipeline.SendOptionsChangeEvent) {

After Change


	final public void userEventTriggered(ChannelHandlerContext ctx, Object evt)
			throws Exception {
		if (log.isTraceEnabled()) {
			log.trace("{} End of the pipeline, User event {}", ctx.channel(), evt);
		}
		if (evt == NettyPipeline.handlerTerminatedEvent()) {
			ContextHandler<?> c = lastContext;
			if (c == null){
				if (log.isDebugEnabled()){
					log.debug("{} No context to dispose", ctx.channel());
				}
				return;
			}
			if (log.isDebugEnabled()){
				log.debug("{} Disposing context {}", ctx.channel(), c);
			}
			lastContext = null;
			c.terminateChannel(ctx.channel());
			return;
		}
		if (evt instanceof NettyPipeline.SendOptionsChangeEvent) {
			if (log.isDebugEnabled()) {
				log.debug("{} New sending options", ctx.channel());
			}
			((NettyPipeline.SendOptionsChangeEvent) evt).configurator()
			                                            .accept(this);